package com.atguigu.flink.chapter05.Environment;

import org.apache.flink.api.common.RuntimeExecutionMode;
import org.apache.flink.api.java.ExecutionEnvironment;
import org.apache.flink.streaming.api.environment.StreamExecutionEnvironment;

/**
 * TODO
 *
 * @author cjp
 * @version 1.0
 * @date 2021/1/20 10:17
 */
public class Flink01_Env {
    public static void main(String[] args) {
        // 批执行环境
        ExecutionEnvironment bend = ExecutionEnvironment.getExecutionEnvironment();
        // 流执行环境
        StreamExecutionEnvironment senv = StreamExecutionEnvironment.getExecutionEnvironment();
        // 1.12版本，可以在流式的执行环境中，指定为 批处理模式 => 为了更像 流批一体
        senv.setRuntimeMode(RuntimeExecutionMode.BATCH);

        // spark里面，运行环境需要明确指定
        //  => idea运行的时候， 创建 ssc.setMaster("local[*]")
        //  => 如果要提交到集群去执行，   不写.setMaster("local[*]")

    }
}
